package org.zbus.thrift;

import org.apache.thrift.TException;

public class ZbusApiImpl implements ZbusApi.Iface {

	@Override
	public String createMq(String mq, int mode) throws TException { 
		return "CreateMQ/OK";
	}

	@Override
	public String produce(String mq, String content) throws TException { 
		return "Produce/OK";
	}

	@Override
	public String consume(String mq, int timeout) throws TException { 
		return "Consume/OK";
	}

	@Override
	public String rpc(String mq, String json_params)
			throws TException { 
		return "Rpc/OK";
	} 
  
 }